99afabdf925fa88d250ce3d915667f59475c636f,jetty-websocket/websocket-server/src/test/java/org/eclipse/jetty/websocket/server/ab/TestABCase1.java,TestABCase1,testCase1_1_7,#,276

Before Change


    @Test
    public void testCase1_1_7() throws Exception
    {
        BlockheadClient client = new BlockheadClient(server.getServerUri());
        try
        {
            client.connect();
            client.sendStandardRequest();
            client.expectUpgradeResponse();

            byte msg[] = new byte[65536];
            Arrays.fill(msg,(byte)'*');

            ByteBuffer buf = ByteBuffer.allocate(msg.length + Generator.OVERHEAD);
            BufferUtil.clearToFill(buf);

            buf.put((byte)(0x00 | FIN | OpCode.TEXT.getCode()));
            putPayloadLength(buf,msg.length);
            putMask(buf);
            buf.put(masked(msg));

            BufferUtil.flipToFlush(buf,0);
            client.writeRaw(buf);

            // Read frame
            Queue<WebSocketFrame> frames = client.readFrames(1,TimeUnit.MILLISECONDS,500);
            WebSocketFrame frame = frames.remove();
            Assert.assertThat("frame should be TEXT frame",frame.getOpCode(),is(OpCode.TEXT));
            Assert.assertThat("Text.payloadLength",frame.getPayloadLength(),is(msg.length));
            ByteBufferAssert.assertEquals("Text.payload",msg,frame.getPayload());
        }
        finally
        {

After Change


    public void testCase1_1_7() throws Exception
    {
        byte payload[] = new byte[65536];
        Arrays.fill(payload,(byte)'*');

        assertEchoFrame(OpCode.TEXT,payload);
    }

    /**